package com.erik.lin.mq.listener;

import com.erik.lin.annotion.MessageListener;
import com.erik.lin.domain.Person;
import com.google.common.eventbus.Subscribe;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * Created by Erik on 2017/4/5.
 */
@MessageListener(queueName = "rec.person")
public class Event2 {
    private Logger LOG = LoggerFactory.getLogger(Event.class);

    @Subscribe
    public void sub(Person person) {
        LOG.info("I've recived message :{}", person.toString());
    }
}

